package com.aikon.wht.paoshan;

/**
 *
 *
 * @author WANGHAITAO273
 */
public class PaoshanOfMQ {

    // rocketmq事务：2pc原理，见rocketmq事务.jpg

    // 防消息丢失：
    // 在生产阶段，你需要捕获消息发送的错误，并重发消息。
    // 在存储阶段，你可以通过配置刷盘和复制相关的参数，让消息写入到多个副本的磁盘上，来确保消息不会因为某个 Broker 宕机或者磁盘损坏而丢失。
    // 在消费阶段，你需要在处理完全部消费业务逻辑之后，再发送消费确认。


}
